package com.andnnl.redis;

import redis.clients.jedis.JedisPubSub;

public class TestPublishClient {
    public static void main(String[] args) {

         RedisSession.operate(s -> {
            JedisPubSub jedisPubSub = new JedisPubSub() {
                @Override
                public void onMessage(String channel, String message) {
                    super.onMessage(channel, message);
                    System.out.println(message);

                }
            };
            s.subscribe(jedisPubSub, "test.a1");
            return null;
        });
    }

    private static void testP() {

    }
}
